package org.redis.cluster.test.transport.redis;

import org.junit.Assert;
import org.junit.Test;
import org.redis.cluster.redis.processor.RedisStatusReplyProcessor;
import org.redis.cluster.redis.transport.reply.RedisStatusReply;

public class RedisStatusReplyProcessorTester {

	@Test
	public void test() {
		RedisStatusReplyProcessor processor=new RedisStatusReplyProcessor();
		RedisStatusReply reply=new RedisStatusReply("test status");
		byte result[]=processor.process(reply);
		Assert.assertEquals("+test status\r\n", new String(result));
	}
}